// 物联网服务，负责接收物联网设备发送的数据消息并保存在数据库

const mqtt = require('mqtt');
// 连接到物联网平台
const client  = mqtt.connect('mqtt://broker-cn.emqx.io:1883');

// 数据服务
const dataService = require('./dataService.js')

client.on('connect', function () {
    client.subscribe('iot/data'); // 订阅物联网设备发布的主题
});

// 监听物联网数据消息
client.on('message', (topic, message) => {
    console.log(message.toString());
    dataService.insert(JSON.parse(message.toString()))
});

module.exports = client